package com.demo.rocketmq.entity;

import lombok.Data;

import java.util.List;
import java.util.Map;

/**
 * @author cyj
 **/
@Data
public class CanalResult<T> {
    private List<T> data ;

    private String database;

    private long es;

    private long id;

    private boolean isDdl;

    private Map<String, String> mysqlType;

    private String old;

    private List<String> pkNames ;

    private String sql;

    private Map<String, Long> sqlType;

    private String table;

    private long ts;

    private String type;
}
